# -*- coding: utf-8 -*-

# @File    : sumo_router.py
# @Date    : 2025-02-19
# @Author  : gaoyuan
import time
from multiprocessing import Pipe
class sumoRouter():
    def __init__(self, config,pipe:Pipe):
        '''
         根据config中的信息
        1. 建立redis连接池
        2. 启动sumo
        :param config: 配置文件
        :param queue: 消息队列
        '''
        self.pipe=pipe
        pass


    # 以下方法名称，根据实际情况做修改
    def check_vsl_changes(self)->bool:
        '''检查船舶数据是否发生变化'''
        pass

    def check_task_changes(self)->bool:
        '''检查任务数据是否变化'''
        pass
    def run(self):
        while True:
            # 从redis 获取数据

            if self.check_task_changes():
                # 更新路网，新路径
                pass
            if self.check_task_changes():
                # 新路径
                pass
            # 如果发生了新的路径，通过queue传递新路径
            # self.pipe.send(new_route)
            time.sleep(2)

def sumoRouter_entry(config,pipe):
    sumo_router=sumoRouter(config,pipe)
    sumo_router.run()